#include "DataManager/DataManager.h"
#include <QDebug>
#include <QMutexLocker>

DataManager::DataManager(QObject* parent)
    : QObject(parent)
{
}

void DataManager::processData(int nodeId, const QString& data)
{
    static QMutex mutex;  // 保护共享数据的互斥锁
    static QMap<int, QString> sharedData;  // 共享数据

    QMutexLocker locker(&mutex);
    sharedData[nodeId] = data;

    qDebug() << "Processed data from Node" << nodeId << ":" << data;

    // 检查是否所有数据都已处理
    if (sharedData.size() == 100)  // 假设有 100 个节点
    {
        qDebug() << "All data processed:" << sharedData;
        emit allDataProcessed();  // 可选：通知其他部分数据已处理完成
    }
}
